package rddSummary.transition.both_key_type

import org.apache.spark.{SparkConf, SparkContext}

object test_zip {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setAppName("test").setMaster("local")
    val sparkContext = new SparkContext(conf)

    val dataRDD1 = sparkContext.makeRDD(List(1,2,3,4))
    val dataRDD2 = sparkContext.makeRDD(List(3,4,5,6))

    /**
     * 将两个RDD中的元素，以键值对的形式进行合并。其中，键值对中的Key 为第 1 个RDD
     * 中的元素，Value 为第 2 个RDD中的相同位置的元素
     *
     * 结果：
     * (1,3)
     * (2,4)
     * (3,5)
     * (4,6)
     */
    val value = dataRDD1.zip(dataRDD2)

    value.collect().foreach(println)

    sparkContext.stop()
  }

}
